package org.example;
import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.common.message.Message;

import java.io.File;
import java.io.FileInputStream;
import java.nio.file.Files;
import java.util.Scanner;

public class IMFileSenderSlice {
    public static void main(String[] args) throws Exception {
        // 创建生产者，并指定生产者组名
        DefaultMQProducer producer = new DefaultMQProducer("file_translate_group");
        // 指定NameServer地址
        producer.setNamesrvAddr("124.71.28.51:9876");
        // 启动生产者
        producer.start();

        // 文件路径
        Scanner filePathScanner=new Scanner(System.in);
        System.out.println("Please in put the file path");
        String filePath = filePathScanner.nextLine();
        File file = new File(filePath);

        // 读取文件内容为字节数组
        byte[] fileBytes = Files.readAllBytes(file.toPath());

        // 创建消息，指定主题、标签和消息体（即文件内容）
        Message msg = new Message("FileTransferTopic", "TagA",file.getName(),fileBytes);

        // 发送消息
        producer.send(msg);
        System.out.println("Send Successfully");

        // 关闭生产者
        producer.shutdown();
    }
}
